package cn.xtcode.domain.activity.service.trial;

import cn.xtcode.domain.activity.adapter.repository.IActivityRepository;
import cn.xtcode.domain.activity.model.entity.MarketProductEntity;
import cn.xtcode.domain.activity.model.entity.TrialBalanceEntity;
import cn.xtcode.types.design.framework.tree.AbstractMultiThreadStrategyRouter;
import cn.xtcode.types.design.framework.tree.AbstractStrategyRouter;

import javax.annotation.Resource;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeoutException;

/**
 * @Author xt-code
 * @Description:
 * @Create 2025/5/6 11:57
 */
public abstract class AbstractGroupBuyMarketSupport<MarketProductEntity, DynamicContext, TrialBalanceEntity> extends AbstractMultiThreadStrategyRouter<MarketProductEntity, DynamicContext, TrialBalanceEntity> {
    /**
     * 异步加载数据等待的时间.超时就拜拜 单位ms
     */
    protected long timeout = 500;

    @Resource
    protected IActivityRepository repository;


    /**
     * 异步加载数据任务
     * 在这里将它实现为空，子类就按需求写，需要的话，就重写
     */
    @Override
    protected void multiThread(MarketProductEntity requestParameter, DynamicContext dynamicContext) throws ExecutionException, InterruptedException, TimeoutException {

    }
}
